c319ba16f46cb8d9a3570cfc22a2ba53d0103177,core/src/main/java/com/aliyun/fs/oss/blk/JetOssFileSystemStore.java,JetOssFileSystemStore,initialize,#URI#Configuration#,80
Before Change
this.conf = conf;
String endpoint = conf.get("fs.oss.endpoint");
String accessKeyId = conf.get("fs.oss.accessKeyId");
String accessKeySecret = conf.get("fs.oss.accessKeySecret");
String securityToken = conf.get("fs.oss.securityToken");
if (securityToken == null) {
this.ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
After Change
}
public void initialize(URI uri, Configuration conf) throws IOException {
if (uri.getHost() == null) {
throw new IllegalArgumentException("Invalid hostname in URI " + uri);
}
this.conf = conf;
String userInfo = uri.getUserInfo();
if (userInfo != null) {
String[] ossCredentials = userInfo.split(":");
if (ossCredentials.length >= 2) {
accessKeyId = ossCredentials[0];
accessKeySecret = ossCredentials[1];
}
if (ossCredentials.length == 3) {
securityToken = ossCredentials[2];
}
}
if (accessKeyId == null) {
accessKeyId = conf.getTrimmed("fs.oss.accessKeyId");
}
if (accessKeySecret == null) {
accessKeySecret = conf.getTrimmed("fs.oss.accessKeySecret");
}
if (securityToken == null) {
securityToken = conf.getTrimmed("fs.oss.securityToken");